﻿import Redis from 'ioredis';

// 创建一个 Redis 客户端
const redis = new Redis({
  host: 'localhost',
  port: 6399,
  connectTimeout: 3000,
  db:1,
  // 设置重连策略
  retryStrategy: (times) => {
    // 每次重连延迟的时间，单位是毫秒
    return 5000;
  },
});

// 连接状态检查
function checkRedisConnection() {
  if (redis.status === 'ready') {
    console.log('Redis 连接成功');
  } else {
    console.log(`当前 Redis 状态: ${redis.status}`);
  }
}

// 监听连接事件
redis.on('connect', () => {
  console.log('连接到 Redis...');
});

redis.on('ready', () => {
  console.log('Redis 已就绪');
});

redis.on('error', (err) => {
  console.error('Redis 连接出错:', err);
});

redis.on('close', () => {
  console.log('Redis 连接关闭');
});

// 示例操作：发送一个命令，看连接是否正常
function executeCommand() {
  redis.set('key', 'value')
    .then(() => {
      console.log('成功设置键值对');
    })
    .catch((err) => {
      console.error('设置键值对时出错:', err);
    });
}

// 定期执行命令（假设每 5 秒执行一次）
// setInterval(executeCommand, 5000);
